package com.demo.example.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author my
 * @version 1.0
 * @title RequestCouponQueue
 * @description <描述内容>
 * @create 2023/2/8 14:47
 **/
public interface RequestCouponQueue {
    String INPUT="coupon-consumer";
    String OUTPUT ="coupon-producer";
    @Input(value = INPUT)
    public SubscribableChannel input();

    @Output(OUTPUT)
    public MessageChannel output();

}
